package com.example.rxjava1;

import rx.Observable;

public class RxJava1Test02 {

    public static void main(String[] args) throws InterruptedException {
        Observable
                .just("www","w3cschool","com")
                .map(i->i.toUpperCase())
                .flatMap(i->Observable.just(i))
                .subscribe(
                        i-> System.out.println(i),
                        e-> System.out.println(e.fillInStackTrace()),
                        ()-> System.out.println("completed")
                        );
        Thread.currentThread().join();
    }
}
